package com.letu.plumelog.client;

import com.letu.cache.redis.RedisOps;
import com.letu.core.plumelog.CompressMessage;
import com.letu.plumelog.exception.LogQueueConnectException;

/**
 * 写入redis队列
 */
public class RedisClient {
    public void pushMessage(String key, CompressMessage compressMessage, RedisOps redisOps) throws LogQueueConnectException {
        redisOps.send(key, compressMessage);
    }
}
